b2a26edba028760b6b228add3462e07949b5065c,components/camel-aws/src/main/java/org/apache/camel/component/aws/sqs/SqsEndpoint.java,SqsEndpoint,doStart,#,75
Before Change
updateAttribute("MessageRetentionPeriod", getConfiguration().getMessageRetentionPeriod());
}
if (getConfiguration().getPolicy() != null) {
updateAttribute("Policy", getConfiguration().getPolicy());
}
}
After Change
request.getAttributes().put(QueueAttributeName.MessageRetentionPeriod.name(), String.valueOf(getConfiguration().getMessageRetentionPeriod()));
}
if (getConfiguration().getPolicy() != null) {
request.getAttributes().put(QueueAttributeName.Policy.name(), String.valueOf(getConfiguration().getPolicy()));
}
LOG.trace("Creating queue [{}] with request [{}]...", configuration.getQueueName(), request);